[INFO] cloning repository https://github.com/TYPEmber/data_distributor
[INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/TYPEmber/data_distributor" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2FTYPEmber%2Fdata_distributor", kill_on_drop: false }`
[INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2FTYPEmber%2Fdata_distributor'...
[INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }`
[INFO] [stdout] 960865b2859c46874e3fb57da2a86631bdebc48c
[INFO] building TYPEmber/data_distributor against master#881c1ac408d93bb7adaa3a51dabab9266e82eee8 for issue-85264
[INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2FTYPEmber%2Fdata_distributor" "/workspace/builds/worker-15/source", kill_on_drop: false }`
[INFO] [stderr] Cloning into '/workspace/builds/worker-15/source'...
[INFO] [stderr] done.
[INFO] validating manifest of git repo https://github.com/TYPEmber/data_distributor on toolchain 881c1ac408d93bb7adaa3a51dabab9266e82eee8
[INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+881c1ac408d93bb7adaa3a51dabab9266e82eee8" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] started tweaking git repo https://github.com/TYPEmber/data_distributor
[INFO] finished tweaking git repo https://github.com/TYPEmber/data_distributor
[INFO] tweaked toml for git repo https://github.com/TYPEmber/data_distributor written to /workspace/builds/worker-15/source/Cargo.toml
[INFO] crate git repo https://github.com/TYPEmber/data_distributor already has a lockfile, it will not be regenerated
[INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+881c1ac408d93bb7adaa3a51dabab9266e82eee8" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] [stderr]  Downloading crates ...
[INFO] [stderr]   Downloaded futures-core v0.3.14
[INFO] [stderr]   Downloaded twoway v0.1.8
[INFO] [stderr]   Downloaded headers v0.3.4
[INFO] [stderr]   Downloaded structopt-derive v0.4.14
[INFO] [stderr]   Downloaded futures-io v0.3.14
[INFO] [stderr]   Downloaded futures-channel v0.3.14
[INFO] [stderr]   Downloaded futures-util v0.3.14
[INFO] [stderr]   Downloaded sha-1 v0.9.4
[INFO] [stderr]   Downloaded tokio-stream v0.1.5
[INFO] [stderr]   Downloaded h2 v0.3.2
[INFO] [stderr]   Downloaded multipart v0.17.1
[INFO] [stderr]   Downloaded crossbeam-epoch v0.9.3
[INFO] [stderr]   Downloaded memoffset v0.6.3
[INFO] [stderr]   Downloaded crossbeam-deque v0.8.0
[INFO] [stderr]   Downloaded winreg v0.8.0
[INFO] [stderr]   Downloaded regex-syntax v0.6.23
[INFO] [stderr]   Downloaded crossbeam-channel v0.5.1
[INFO] [stderr]   Downloaded futures v0.3.14
[INFO] [stderr]   Downloaded futures-task v0.3.14
[INFO] [stderr]   Downloaded vswhom-sys v0.1.0
[INFO] [stderr]   Downloaded vswhom v0.1.0
[INFO] [stderr]   Downloaded tracing v0.1.25
[INFO] [stderr]   Downloaded warp v0.3.1
[INFO] [stderr]   Downloaded regex v1.4.5
[INFO] [stderr]   Downloaded embed-resource v1.6.2
[INFO] [stderr]   Downloaded crossbeam-queue v0.3.1
[INFO] [stderr]   Downloaded crossbeam v0.8.0
[INFO] [stderr]   Downloaded input_buffer v0.4.0
[INFO] [stderr]   Downloaded url v2.2.1
[INFO] [stderr]   Downloaded tungstenite v0.12.0
[INFO] [stderr]   Downloaded cpuid-bool v0.1.2
[INFO] [stderr]   Downloaded value-bag v1.0.0-alpha.6
[INFO] [stderr]   Downloaded futures-sink v0.3.14
[INFO] [stderr]   Downloaded lock_api v0.4.3
[INFO] [stderr]   Downloaded redox_syscall v0.2.6
[INFO] [stderr]   Downloaded structopt v0.3.21
[INFO] [stderr]   Downloaded headers-core v0.2.0
[INFO] [stderr]   Downloaded buf_redux v0.8.4
[INFO] [stderr]   Downloaded http-body v0.4.1
[INFO] [stderr]   Downloaded hyper v0.14.5
[INFO] [stderr]   Downloaded tokio-tungstenite v0.13.0
[INFO] [stderr]   Downloaded tracing-core v0.1.17
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-15/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-15/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:20528e8c29e4536546f0102ce88568b16ea7538393a33fcca951030f7af10457" "/opt/rustwide/cargo-home/bin/cargo" "+881c1ac408d93bb7adaa3a51dabab9266e82eee8" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] 77d5f03202cf64ba21c411f1c526e87db91161105a75a18bbde3ef7a3fe20472
[INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap.
[INFO] running `Command { std: "docker" "start" "-a" "77d5f03202cf64ba21c411f1c526e87db91161105a75a18bbde3ef7a3fe20472", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "77d5f03202cf64ba21c411f1c526e87db91161105a75a18bbde3ef7a3fe20472", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "77d5f03202cf64ba21c411f1c526e87db91161105a75a18bbde3ef7a3fe20472", kill_on_drop: false }`
[INFO] [stdout] 77d5f03202cf64ba21c411f1c526e87db91161105a75a18bbde3ef7a3fe20472
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-15/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-15/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:20528e8c29e4536546f0102ce88568b16ea7538393a33fcca951030f7af10457" "/opt/rustwide/cargo-home/bin/cargo" "+881c1ac408d93bb7adaa3a51dabab9266e82eee8" "build" "--frozen" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] c802826cdc19365e02583ee6186031e6294310a88e9eea1fcedd41ab717b3aca
[INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap.
[INFO] running `Command { std: "docker" "start" "-a" "c802826cdc19365e02583ee6186031e6294310a88e9eea1fcedd41ab717b3aca", kill_on_drop: false }`
[INFO] [stderr]    Compiling libc v0.2.93
[INFO] [stderr]    Compiling unicode-xid v0.2.1
[INFO] [stderr]    Compiling syn v1.0.69
[INFO] [stderr]    Compiling autocfg v1.0.1
[INFO] [stderr]    Compiling value-bag v1.0.0-alpha.6
[INFO] [stderr]    Compiling log v0.4.14
[INFO] [stderr]    Compiling scopeguard v1.1.0
[INFO] [stderr]    Compiling itoa v0.4.7
[INFO] [stderr]    Compiling typenum v1.13.0
[INFO] [stderr]    Compiling ppv-lite86 v0.2.10
[INFO] [stderr]    Compiling futures-core v0.3.14
[INFO] [stderr]    Compiling fnv v1.0.7
[INFO] [stderr]    Compiling futures-sink v0.3.14
[INFO] [stderr]    Compiling httparse v1.4.0
[INFO] [stderr]    Compiling tinyvec_macros v0.1.0
[INFO] [stderr]    Compiling getrandom v0.1.16
[INFO] [stderr]    Compiling slab v0.4.2
[INFO] [stderr]    Compiling bitflags v1.2.1
[INFO] [stderr]    Compiling pin-utils v0.1.0
[INFO] [stderr]    Compiling futures-task v0.3.14
[INFO] [stderr]    Compiling percent-encoding v2.1.0
[INFO] [stderr]    Compiling cpuid-bool v0.1.2
[INFO] [stderr]    Compiling opaque-debug v0.3.0
[INFO] [stderr]    Compiling ryu v1.0.5
[INFO] [stderr]    Compiling base64 v0.13.0
[INFO] [stderr]    Compiling remove_dir_all v0.5.3
[INFO] [stderr]    Compiling unicode-segmentation v1.7.1
[INFO] [stderr]    Compiling safemem v0.3.3
[INFO] [stderr]    Compiling serde_json v1.0.64
[INFO] [stderr]    Compiling utf-8 v0.7.6
[INFO] [stderr]    Compiling unicode-width v0.1.8
[INFO] [stderr]    Compiling ansi_term v0.11.0
[INFO] [stderr]    Compiling strsim v0.8.0
[INFO] [stderr]    Compiling futures-io v0.3.14
[INFO] [stderr]    Compiling vec_map v0.8.2
[INFO] [stderr]    Compiling regex-syntax v0.6.23
[INFO] [stderr]    Compiling scoped-tls v1.0.0
[INFO] [stderr]    Compiling instant v0.1.9
[INFO] [stderr]    Compiling generic-array v0.14.4
[INFO] [stderr]    Compiling unicase v2.6.0
[INFO] [stderr]    Compiling proc-macro-error-attr v1.0.4
[INFO] [stderr]    Compiling unicode-bidi v0.3.5
[INFO] [stderr]    Compiling tracing-core v0.1.17
[INFO] [stderr]    Compiling proc-macro-error v1.0.4
[INFO] [stderr]    Compiling input_buffer v0.4.0
[INFO] [stderr]    Compiling embed-resource v1.6.2
[INFO] [stderr]    Compiling tinyvec v1.2.0
[INFO] [stderr]    Compiling lock_api v0.4.3
[INFO] [stderr]    Compiling proc-macro2 v1.0.26
[INFO] [stderr]    Compiling textwrap v0.11.0
[INFO] [stderr]    Compiling http v0.2.4
[INFO] [stderr]    Compiling form_urlencoded v1.0.1
[INFO] [stderr]    Compiling futures-util v0.3.14
[INFO] [stderr]    Compiling futures-channel v0.3.14
[INFO] [stderr]    Compiling twoway v0.1.8
[INFO] [stderr]    Compiling buf_redux v0.8.4
[INFO] [stderr]    Compiling data_distributor v0.1.0 (/opt/rustwide/workdir)
[INFO] [stderr]    Compiling tokio v1.5.0
[INFO] [stderr]    Compiling crossbeam-utils v0.8.3
[INFO] [stderr]    Compiling indexmap v1.6.2
[INFO] [stderr]    Compiling memoffset v0.6.3
[INFO] [stderr]    Compiling heck v0.3.2
[INFO] [stderr]    Compiling quote v1.0.9
[INFO] [stderr]    Compiling mime_guess v2.0.3
[INFO] [stderr]    Compiling unicode-normalization v0.1.17
[INFO] [stderr]    Compiling crossbeam-epoch v0.9.3
[INFO] [stderr]    Compiling crossbeam-channel v0.5.1
[INFO] [stderr]    Compiling crossbeam-queue v0.3.1
[INFO] [stderr]    Compiling num_cpus v1.13.0
[INFO] [stderr]    Compiling getrandom v0.2.2
[INFO] [stderr]    Compiling parking_lot_core v0.8.3
[INFO] [stderr]    Compiling signal-hook-registry v1.3.0
[INFO] [stderr]    Compiling atty v0.2.14
[INFO] [stderr]    Compiling socket2 v0.4.0
[INFO] [stderr]    Compiling time v0.1.43
[INFO] [stderr]    Compiling clap v2.33.3
[INFO] [stderr]    Compiling crossbeam-deque v0.8.0
[INFO] [stderr]    Compiling parking_lot v0.11.1
[INFO] [stderr]    Compiling rand_core v0.6.2
[INFO] [stderr]    Compiling dashmap v4.0.2
[INFO] [stderr]    Compiling rand_core v0.5.1
[INFO] [stderr]    Compiling crossbeam v0.8.0
[INFO] [stderr]    Compiling rand_chacha v0.3.0
[INFO] [stderr]    Compiling rand_chacha v0.2.2
[INFO] [stderr]    Compiling rand v0.7.3
[INFO] [stderr]    Compiling block-buffer v0.9.0
[INFO] [stderr]    Compiling digest v0.9.0
[INFO] [stderr]    Compiling rand v0.8.3
[INFO] [stderr]    Compiling idna v0.2.3
[INFO] [stderr]    Compiling sha-1 v0.9.4
[INFO] [stderr]    Compiling headers-core v0.2.0
[INFO] [stderr]    Compiling http-body v0.4.1
[INFO] [stderr]    Compiling headers v0.3.4
[INFO] [stderr]    Compiling url v2.2.1
[INFO] [stderr]    Compiling regex v1.4.5
[INFO] [stderr]    Compiling tempfile v3.2.0
[INFO] [stderr]    Compiling futures v0.3.14
[INFO] [stderr]    Compiling ctor v0.1.20
[INFO] [stderr]    Compiling tokio-macros v1.1.0
[INFO] [stderr]    Compiling pin-project-internal v1.0.7
[INFO] [stderr]    Compiling serde_derive v1.0.125
[INFO] [stderr]    Compiling structopt-derive v0.4.14
[INFO] [stderr]    Compiling mio v0.7.11
[INFO] [stderr]    Compiling tracing v0.1.25
[INFO] [stderr]    Compiling tungstenite v0.12.0
[INFO] [stderr]    Compiling want v0.3.0
[INFO] [stderr]    Compiling multipart v0.17.1
[INFO] [stderr]    Compiling pin-project v1.0.7
[INFO] [stderr]    Compiling structopt v0.3.21
[INFO] [stderr]    Compiling serde v1.0.125
[INFO] [stderr]    Compiling tokio-util v0.6.6
[INFO] [stderr]    Compiling tokio-stream v0.1.5
[INFO] [stderr]    Compiling tokio-tungstenite v0.13.0
[INFO] [stderr]    Compiling h2 v0.3.2
[INFO] [stderr]    Compiling serde_urlencoded v0.7.0
[INFO] [stderr]    Compiling hyper v0.14.5
[INFO] [stderr]    Compiling warp v0.3.1
[INFO] [stdout] warning: unused imports: `debug`, `error`, `trace`
[INFO] [stdout]  --> src/lib.rs:3:11
[INFO] [stdout]   |
[INFO] [stdout] 3 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^        ^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Mutex`
[INFO] [stdout]  --> src/lib.rs:4:22
[INFO] [stdout]   |
[INFO] [stdout] 4 | use std::sync::{Arc, Mutex};
[INFO] [stdout]   |                      ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `info`, `trace`, `warn`
[INFO] [stdout]  --> src/logger.rs:1:11
[INFO] [stdout]   |
[INFO] [stdout] 1 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^  ^^^^  ^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `SetLoggerError`
[INFO] [stdout]   --> src/logger.rs:48:24
[INFO] [stdout]    |
[INFO] [stdout] 48 | use log::{LevelFilter, SetLoggerError};
[INFO] [stdout]    |                        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `dashmap::mapref::one::Ref`
[INFO] [stdout]  --> src/server.rs:1:5
[INFO] [stdout]   |
[INFO] [stdout] 1 | use dashmap::mapref::one::Ref;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `trace`, `warn`
[INFO] [stdout]  --> src/server.rs:3:11
[INFO] [stdout]   |
[INFO] [stdout] 3 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^        ^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `HashSet`
[INFO] [stdout]   --> src/lib.rs:78:33
[INFO] [stdout]    |
[INFO] [stdout] 78 | use std::collections::{HashMap, HashSet};
[INFO] [stdout]    |                                 ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:141:9
[INFO] [stdout]     |
[INFO] [stdout] 141 |         mut self,
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable expression
[INFO] [stdout]    --> src/server.rs:107:17
[INFO] [stdout]     |
[INFO] [stdout] 103 |                     return Ok("stop success");
[INFO] [stdout]     |                     ------------------------- any code following this expression is unreachable
[INFO] [stdout] ...
[INFO] [stdout] 107 |                 Err(warp::reject::not_found())
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unreachable expression
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unreachable_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `interval`
[INFO] [stdout]    --> src/lib.rs:308:25
[INFO] [stdout]     |
[INFO] [stdout] 308 |                 let mut interval =  tokio::time::interval(tokio::time::Duration::from_millis(1));
[INFO] [stdout]     |                         ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_interval`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `stop_for_send_thread_1`
[INFO] [stdout]    --> src/lib.rs:302:13
[INFO] [stdout]     |
[INFO] [stdout] 302 |     let mut stop_for_send_thread_1 = stop_broadcast_sender.subscribe();
[INFO] [stdout]     |             ^^^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_stop_for_send_thread_1`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `send_size1`
[INFO] [stdout]    --> src/lib.rs:304:13
[INFO] [stdout]     |
[INFO] [stdout] 304 |     let mut send_size1 = send_size.clone();
[INFO] [stdout]     |             ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_send_size1`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]    --> src/lib.rs:166:44
[INFO] [stdout]     |
[INFO] [stdout] 166 | ...                   if let Err(e) = sender_map
[INFO] [stdout]     |                                  ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:308:21
[INFO] [stdout]     |
[INFO] [stdout] 308 |                 let mut interval =  tokio::time::interval(tokio::time::Duration::from_millis(1));
[INFO] [stdout]     |                     ----^^^^^^^^
[INFO] [stdout]     |                     |
[INFO] [stdout]     |                     help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:302:9
[INFO] [stdout]     |
[INFO] [stdout] 302 |     let mut stop_for_send_thread_1 = stop_broadcast_sender.subscribe();
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:303:9
[INFO] [stdout]     |
[INFO] [stdout] 303 |     let mut send_size = Arc::new(AtomicUsize::new(0));
[INFO] [stdout]     |         ----^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:304:9
[INFO] [stdout]     |
[INFO] [stdout] 304 |     let mut send_size1 = send_size.clone();
[INFO] [stdout]     |         ----^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 17 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `info`, `trace`, `warn`
[INFO] [stdout]  --> src/bin/test_utils/sender.rs:2:11
[INFO] [stdout]   |
[INFO] [stdout] 2 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^  ^^^^  ^^^^^  ^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Domain`, `SockAddr`, `Socket`, `Type`
[INFO] [stdout]  --> src/bin/test_utils/sender.rs:3:15
[INFO] [stdout]   |
[INFO] [stdout] 3 | use socket2::{Domain, SockAddr, Socket, Type};
[INFO] [stdout]   |               ^^^^^^  ^^^^^^^^  ^^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `convert::Infallible`, `net::SocketAddr`
[INFO] [stdout]  --> src/bin/test_utils/sender.rs:6:11
[INFO] [stdout]   |
[INFO] [stdout] 6 | use std::{convert::Infallible, net::SocketAddr};
[INFO] [stdout]   |           ^^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Duration`, `sleep`
[INFO] [stdout]  --> src/bin/test_utils/sender.rs:9:19
[INFO] [stdout]   |
[INFO] [stdout] 9 | use tokio::time::{sleep, Duration};
[INFO] [stdout]   |                   ^^^^^  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `trace`
[INFO] [stdout]  --> src/bin/main.rs:5:11
[INFO] [stdout]   |
[INFO] [stdout] 5 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^        ^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `info`, `trace`, `warn`
[INFO] [stdout]  --> src/bin/test_utils/receiver.rs:2:11
[INFO] [stdout]   |
[INFO] [stdout] 2 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^  ^^^^  ^^^^^  ^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::str`
[INFO] [stdout]  --> src/bin/test_utils/receiver.rs:5:5
[INFO] [stdout]   |
[INFO] [stdout] 5 | use std::str;
[INFO] [stdout]   |     ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `convert::Infallible`, `net::SocketAddr`
[INFO] [stdout]  --> src/bin/test_utils/receiver.rs:6:11
[INFO] [stdout]   |
[INFO] [stdout] 6 | use std::{convert::Infallible, net::SocketAddr};
[INFO] [stdout]   |           ^^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Duration`, `sleep`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:10:19
[INFO] [stdout]    |
[INFO] [stdout] 10 | use tokio::time::{sleep, Duration};
[INFO] [stdout]    |                   ^^^^^  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/main.rs:113:13
[INFO] [stdout]     |
[INFO] [stdout] 113 |         let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |             ----^^^^^
[INFO] [stdout]     |             |
[INFO] [stdout]     |             help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/main.rs:133:17
[INFO] [stdout]     |
[INFO] [stdout] 133 |             let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |                 ----^^^^^
[INFO] [stdout]     |                 |
[INFO] [stdout]     |                 help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/main.rs:105:9
[INFO] [stdout]     |
[INFO] [stdout] 105 |     let mut interval = tokio::time::interval(tokio::time::Duration::from_millis(5_000));
[INFO] [stdout]     |         ----^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:101:9
[INFO] [stdout]     |
[INFO] [stdout] 101 |     let mut time = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:103:9
[INFO] [stdout]     |
[INFO] [stdout] 103 |     let mut send_bits_count_last = 0usize;
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:108:9
[INFO] [stdout]     |
[INFO] [stdout] 108 |     let mut data = &mut arr[..];
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:109:9
[INFO] [stdout]     |
[INFO] [stdout] 109 |     let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:113:13
[INFO] [stdout]     |
[INFO] [stdout] 113 |         let mut time_f64 = time.elapsed().unwrap().as_secs_f64();
[INFO] [stdout]     |             ----^^^^^^^^
[INFO] [stdout]     |             |
[INFO] [stdout]     |             help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `interval`
[INFO] [stdout]    --> src/bin/main.rs:105:13
[INFO] [stdout]     |
[INFO] [stdout] 105 |     let mut interval = tokio::time::interval(tokio::time::Duration::from_millis(5_000));
[INFO] [stdout]     |             ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_interval`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `k`
[INFO] [stdout]    --> src/bin/main.rs:127:9
[INFO] [stdout]     |
[INFO] [stdout] 127 |     for k in 0..multi_count {
[INFO] [stdout]     |         ^ help: if this is intentional, prefix it with an underscore: `_k`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:174:9
[INFO] [stdout]     |
[INFO] [stdout] 174 |     let mut time = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:176:9
[INFO] [stdout]     |
[INFO] [stdout] 176 |     let mut send_bits_count_last = 0usize;
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:181:9
[INFO] [stdout]     |
[INFO] [stdout] 181 |     let mut data = &mut arr[..];
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:182:9
[INFO] [stdout]     |
[INFO] [stdout] 182 |     let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:186:13
[INFO] [stdout]     |
[INFO] [stdout] 186 |         let mut time_f64 = time.elapsed().unwrap().as_secs_f64();
[INFO] [stdout]     |             ----^^^^^^^^
[INFO] [stdout]     |             |
[INFO] [stdout]     |             help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:308:9
[INFO] [stdout]     |
[INFO] [stdout] 308 |     let mut socket = crate::generate_socket(any_addr, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:314:9
[INFO] [stdout]     |
[INFO] [stdout] 314 |     let mut data = &mut arr[..];
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:392:9
[INFO] [stdout]     |
[INFO] [stdout] 392 |     let mut socket = crate::generate_socket(any_addr, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:398:9
[INFO] [stdout]     |
[INFO] [stdout] 398 |     let mut data = &mut arr[..];
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:99:9
[INFO] [stdout]    |
[INFO] [stdout] 99 |     let mut watch = std::time::SystemTime::now();
[INFO] [stdout]    |         ----^^^^^
[INFO] [stdout]    |         |
[INFO] [stdout]    |         help: remove this `mut`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `test_socket_send_limited`
[INFO] [stdout]    --> src/bin/main.rs:104:10
[INFO] [stdout]     |
[INFO] [stdout] 104 | async fn test_socket_send_limited() {
[INFO] [stdout]     |          ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/main.rs:116:13
[INFO] [stdout]     |
[INFO] [stdout] 116 |             socket.send_to(&data, addr).await;
[INFO] [stdout]     |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_must_use)]` on by default
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/main.rs:136:17
[INFO] [stdout]     |
[INFO] [stdout] 136 |                 socket.send_to(&data, addr).await;
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:152:9
[INFO] [stdout]     |
[INFO] [stdout] 152 |     let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:47:16
[INFO] [stdout]    |
[INFO] [stdout] 47 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:66:16
[INFO] [stdout]    |
[INFO] [stdout] 66 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:69:17
[INFO] [stdout]    |
[INFO] [stdout] 69 |             Err(e) => {}
[INFO] [stdout]    |                 ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:82:16
[INFO] [stdout]    |
[INFO] [stdout] 82 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:85:17
[INFO] [stdout]    |
[INFO] [stdout] 85 |             Err(e) => {}
[INFO] [stdout]    |                 ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `send_bits_count_last`
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:103:13
[INFO] [stdout]     |
[INFO] [stdout] 103 |     let mut send_bits_count_last = 0usize;
[INFO] [stdout]     |             ^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_send_bits_count_last`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `pkg_num`
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:165:5
[INFO] [stdout]     |
[INFO] [stdout] 165 |     pkg_num: u32,
[INFO] [stdout]     |     ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_pkg_num`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `send_bits_count_last`
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:176:13
[INFO] [stdout]     |
[INFO] [stdout] 176 |     let mut send_bits_count_last = 0usize;
[INFO] [stdout]     |             ^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_send_bits_count_last`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:247:9
[INFO] [stdout]     |
[INFO] [stdout] 247 |     let mut socket = crate::generate_socket(distributor_ip, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:248:9
[INFO] [stdout]     |
[INFO] [stdout] 248 |     let mut socket_parameter = crate::generate_socket(direct_ip, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:259:9
[INFO] [stdout]     |
[INFO] [stdout] 259 |     let mut buffer = vec![0u8; buffer_length];
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `recv_tcp_f64`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:76:10
[INFO] [stdout]    |
[INFO] [stdout] 76 | async fn recv_tcp_f64(stream: &TcpStream, buffer_length: usize) -> Result<f64, Box<dyn Error>> {
[INFO] [stdout]    |          ^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused implementer of `Future` that must be used
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:368:5
[INFO] [stdout]     |
[INFO] [stdout] 368 |     send_tcp(&stream_stop_2nd, data);
[INFO] [stdout]     |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_must_use)]` on by default
[INFO] [stdout]     = note: futures do nothing unless you `.await` or poll them
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused implementer of `Future` that must be used
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:458:5
[INFO] [stdout]     |
[INFO] [stdout] 458 |     send_tcp(&stream_stop_2nd, data);
[INFO] [stdout]     |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: futures do nothing unless you `.await` or poll them
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:344:9
[INFO] [stdout]     |
[INFO] [stdout] 344 |     let mut socket = crate::generate_socket(distributor_ip, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:345:9
[INFO] [stdout]     |
[INFO] [stdout] 345 |     let mut socket_parameter = crate::generate_socket(direct_ip, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:356:9
[INFO] [stdout]     |
[INFO] [stdout] 356 |     let mut buffer = vec![0u8; buffer_length];
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:41:16
[INFO] [stdout]    |
[INFO] [stdout] 41 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:60:16
[INFO] [stdout]    |
[INFO] [stdout] 60 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:63:17
[INFO] [stdout]    |
[INFO] [stdout] 63 |             Err(e) => {}
[INFO] [stdout]    |                 ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:76:16
[INFO] [stdout]    |
[INFO] [stdout] 76 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:79:17
[INFO] [stdout]    |
[INFO] [stdout] 79 |             Err(e) => {}
[INFO] [stdout]    |                 ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `duration_time` is never read
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:168:25
[INFO] [stdout]     |
[INFO] [stdout] 168 |                         duration_time=watch.elapsed().unwrap().as_secs_f64();
[INFO] [stdout]     |                         ^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_assignments)]` on by default
[INFO] [stdout]     = help: maybe it is overwritten before being read?
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `time_limit`
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:140:5
[INFO] [stdout]     |
[INFO] [stdout] 140 |     time_limit: f64,
[INFO] [stdout]     |     ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_time_limit`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `buffer`
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:259:13
[INFO] [stdout]     |
[INFO] [stdout] 259 |     let mut buffer = vec![0u8; buffer_length];
[INFO] [stdout]     |             ^^^^^^ help: if this is intentional, prefix it with an underscore: `_buffer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `buffer`
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:356:13
[INFO] [stdout]     |
[INFO] [stdout] 356 |     let mut buffer = vec![0u8; buffer_length];
[INFO] [stdout]     |             ^^^^^^ help: if this is intentional, prefix it with an underscore: `_buffer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:105:17
[INFO] [stdout]     |
[INFO] [stdout] 105 |                 socket.recv(&mut buffer).await;
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_must_use)]` on by default
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:127:16
[INFO] [stdout]     |
[INFO] [stdout] 127 |                recv_tcp_u32(&stream_stop,buffer_length).await;
[INFO] [stdout]     |                ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:158:17
[INFO] [stdout]     |
[INFO] [stdout] 158 |                 socket.recv(&mut buffer).await;
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:180:16
[INFO] [stdout]     |
[INFO] [stdout] 180 |                recv_tcp_u32(&stream_stop,buffer_length).await;
[INFO] [stdout]     |                ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 29 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 25 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 9 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished dev [unoptimized + debuginfo] target(s) in 1m 28s
[INFO] running `Command { std: "docker" "inspect" "c802826cdc19365e02583ee6186031e6294310a88e9eea1fcedd41ab717b3aca", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "c802826cdc19365e02583ee6186031e6294310a88e9eea1fcedd41ab717b3aca", kill_on_drop: false }`
[INFO] [stdout] c802826cdc19365e02583ee6186031e6294310a88e9eea1fcedd41ab717b3aca
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-15/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-15/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:20528e8c29e4536546f0102ce88568b16ea7538393a33fcca951030f7af10457" "/opt/rustwide/cargo-home/bin/cargo" "+881c1ac408d93bb7adaa3a51dabab9266e82eee8" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }`
[INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap.
[INFO] [stdout] 54173d058f502ccd288749721308b629969dffbadecdc37da85a6d7d9f7fe523
[INFO] running `Command { std: "docker" "start" "-a" "54173d058f502ccd288749721308b629969dffbadecdc37da85a6d7d9f7fe523", kill_on_drop: false }`
[INFO] [stderr]    Compiling data_distributor v0.1.0 (/opt/rustwide/workdir)
[INFO] [stdout] warning: unused imports: `debug`, `error`, `trace`
[INFO] [stdout]  --> src/lib.rs:3:11
[INFO] [stdout]   |
[INFO] [stdout] 3 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^        ^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Mutex`
[INFO] [stdout]  --> src/lib.rs:4:22
[INFO] [stdout]   |
[INFO] [stdout] 4 | use std::sync::{Arc, Mutex};
[INFO] [stdout]   |                      ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `info`, `trace`, `warn`
[INFO] [stdout]  --> src/logger.rs:1:11
[INFO] [stdout]   |
[INFO] [stdout] 1 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^  ^^^^  ^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `SetLoggerError`
[INFO] [stdout]   --> src/logger.rs:48:24
[INFO] [stdout]    |
[INFO] [stdout] 48 | use log::{LevelFilter, SetLoggerError};
[INFO] [stdout]    |                        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `dashmap::mapref::one::Ref`
[INFO] [stdout]  --> src/server.rs:1:5
[INFO] [stdout]   |
[INFO] [stdout] 1 | use dashmap::mapref::one::Ref;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `trace`, `warn`
[INFO] [stdout]  --> src/server.rs:3:11
[INFO] [stdout]   |
[INFO] [stdout] 3 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^        ^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `HashSet`
[INFO] [stdout]   --> src/lib.rs:78:33
[INFO] [stdout]    |
[INFO] [stdout] 78 | use std::collections::{HashMap, HashSet};
[INFO] [stdout]    |                                 ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:141:9
[INFO] [stdout]     |
[INFO] [stdout] 141 |         mut self,
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable expression
[INFO] [stdout]    --> src/server.rs:107:17
[INFO] [stdout]     |
[INFO] [stdout] 103 |                     return Ok("stop success");
[INFO] [stdout]     |                     ------------------------- any code following this expression is unreachable
[INFO] [stdout] ...
[INFO] [stdout] 107 |                 Err(warp::reject::not_found())
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unreachable expression
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unreachable_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `interval`
[INFO] [stdout]    --> src/lib.rs:308:25
[INFO] [stdout]     |
[INFO] [stdout] 308 |                 let mut interval =  tokio::time::interval(tokio::time::Duration::from_millis(1));
[INFO] [stdout]     |                         ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_interval`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `stop_for_send_thread_1`
[INFO] [stdout]    --> src/lib.rs:302:13
[INFO] [stdout]     |
[INFO] [stdout] 302 |     let mut stop_for_send_thread_1 = stop_broadcast_sender.subscribe();
[INFO] [stdout]     |             ^^^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_stop_for_send_thread_1`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `send_size1`
[INFO] [stdout]    --> src/lib.rs:304:13
[INFO] [stdout]     |
[INFO] [stdout] 304 |     let mut send_size1 = send_size.clone();
[INFO] [stdout]     |             ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_send_size1`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]    --> src/lib.rs:166:44
[INFO] [stdout]     |
[INFO] [stdout] 166 | ...                   if let Err(e) = sender_map
[INFO] [stdout]     |                                  ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:308:21
[INFO] [stdout]     |
[INFO] [stdout] 308 |                 let mut interval =  tokio::time::interval(tokio::time::Duration::from_millis(1));
[INFO] [stdout]     |                     ----^^^^^^^^
[INFO] [stdout]     |                     |
[INFO] [stdout]     |                     help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:302:9
[INFO] [stdout]     |
[INFO] [stdout] 302 |     let mut stop_for_send_thread_1 = stop_broadcast_sender.subscribe();
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:303:9
[INFO] [stdout]     |
[INFO] [stdout] 303 |     let mut send_size = Arc::new(AtomicUsize::new(0));
[INFO] [stdout]     |         ----^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:304:9
[INFO] [stdout]     |
[INFO] [stdout] 304 |     let mut send_size1 = send_size.clone();
[INFO] [stdout]     |         ----^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 17 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `trace`
[INFO] [stdout]  --> src/bin/main.rs:5:11
[INFO] [stdout]   |
[INFO] [stdout] 5 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^        ^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `info`, `trace`, `warn`
[INFO] [stdout]  --> src/bin/test_utils/receiver.rs:2:11
[INFO] [stdout]   |
[INFO] [stdout] 2 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^  ^^^^  ^^^^^  ^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::str`
[INFO] [stdout]  --> src/bin/test_utils/receiver.rs:5:5
[INFO] [stdout]   |
[INFO] [stdout] 5 | use std::str;
[INFO] [stdout]   |     ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `convert::Infallible`, `net::SocketAddr`
[INFO] [stdout]  --> src/bin/test_utils/receiver.rs:6:11
[INFO] [stdout]   |
[INFO] [stdout] 6 | use std::{convert::Infallible, net::SocketAddr};
[INFO] [stdout]   |           ^^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Duration`, `sleep`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:10:19
[INFO] [stdout]    |
[INFO] [stdout] 10 | use tokio::time::{sleep, Duration};
[INFO] [stdout]    |                   ^^^^^  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `info`, `trace`, `warn`
[INFO] [stdout]  --> src/bin/test_utils/sender.rs:2:11
[INFO] [stdout]   |
[INFO] [stdout] 2 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^  ^^^^  ^^^^^  ^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Domain`, `SockAddr`, `Socket`, `Type`
[INFO] [stdout]  --> src/bin/test_utils/sender.rs:3:15
[INFO] [stdout]   |
[INFO] [stdout] 3 | use socket2::{Domain, SockAddr, Socket, Type};
[INFO] [stdout]   |               ^^^^^^  ^^^^^^^^  ^^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `convert::Infallible`, `net::SocketAddr`
[INFO] [stdout]  --> src/bin/test_utils/sender.rs:6:11
[INFO] [stdout]   |
[INFO] [stdout] 6 | use std::{convert::Infallible, net::SocketAddr};
[INFO] [stdout]   |           ^^^^^^^^^^^^^^^^^^^  ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Duration`, `sleep`
[INFO] [stdout]  --> src/bin/test_utils/sender.rs:9:19
[INFO] [stdout]   |
[INFO] [stdout] 9 | use tokio::time::{sleep, Duration};
[INFO] [stdout]   |                   ^^^^^  ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/main.rs:113:13
[INFO] [stdout]     |
[INFO] [stdout] 113 |         let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |             ----^^^^^
[INFO] [stdout]     |             |
[INFO] [stdout]     |             help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/main.rs:133:17
[INFO] [stdout]     |
[INFO] [stdout] 133 |             let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |                 ----^^^^^
[INFO] [stdout]     |                 |
[INFO] [stdout]     |                 help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/main.rs:105:9
[INFO] [stdout]     |
[INFO] [stdout] 105 |     let mut interval = tokio::time::interval(tokio::time::Duration::from_millis(5_000));
[INFO] [stdout]     |         ----^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:101:9
[INFO] [stdout]     |
[INFO] [stdout] 101 |     let mut time = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:103:9
[INFO] [stdout]     |
[INFO] [stdout] 103 |     let mut send_bits_count_last = 0usize;
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:108:9
[INFO] [stdout]     |
[INFO] [stdout] 108 |     let mut data = &mut arr[..];
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:109:9
[INFO] [stdout]     |
[INFO] [stdout] 109 |     let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:113:13
[INFO] [stdout]     |
[INFO] [stdout] 113 |         let mut time_f64 = time.elapsed().unwrap().as_secs_f64();
[INFO] [stdout]     |             ----^^^^^^^^
[INFO] [stdout]     |             |
[INFO] [stdout]     |             help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `interval`
[INFO] [stdout]    --> src/bin/main.rs:105:13
[INFO] [stdout]     |
[INFO] [stdout] 105 |     let mut interval = tokio::time::interval(tokio::time::Duration::from_millis(5_000));
[INFO] [stdout]     |             ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_interval`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `k`
[INFO] [stdout]    --> src/bin/main.rs:127:9
[INFO] [stdout]     |
[INFO] [stdout] 127 |     for k in 0..multi_count {
[INFO] [stdout]     |         ^ help: if this is intentional, prefix it with an underscore: `_k`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:174:9
[INFO] [stdout]     |
[INFO] [stdout] 174 |     let mut time = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:176:9
[INFO] [stdout]     |
[INFO] [stdout] 176 |     let mut send_bits_count_last = 0usize;
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:181:9
[INFO] [stdout]     |
[INFO] [stdout] 181 |     let mut data = &mut arr[..];
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:182:9
[INFO] [stdout]     |
[INFO] [stdout] 182 |     let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:186:13
[INFO] [stdout]     |
[INFO] [stdout] 186 |         let mut time_f64 = time.elapsed().unwrap().as_secs_f64();
[INFO] [stdout]     |             ----^^^^^^^^
[INFO] [stdout]     |             |
[INFO] [stdout]     |             help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:99:9
[INFO] [stdout]    |
[INFO] [stdout] 99 |     let mut watch = std::time::SystemTime::now();
[INFO] [stdout]    |         ----^^^^^
[INFO] [stdout]    |         |
[INFO] [stdout]    |         help: remove this `mut`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:308:9
[INFO] [stdout]     |
[INFO] [stdout] 308 |     let mut socket = crate::generate_socket(any_addr, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:314:9
[INFO] [stdout]     |
[INFO] [stdout] 314 |     let mut data = &mut arr[..];
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `test_socket_send_limited`
[INFO] [stdout]    --> src/bin/main.rs:104:10
[INFO] [stdout]     |
[INFO] [stdout] 104 | async fn test_socket_send_limited() {
[INFO] [stdout]     |          ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:152:9
[INFO] [stdout]     |
[INFO] [stdout] 152 |     let mut watch = std::time::SystemTime::now();
[INFO] [stdout]     |         ----^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/main.rs:116:13
[INFO] [stdout]     |
[INFO] [stdout] 116 |             socket.send_to(&data, addr).await;
[INFO] [stdout]     |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_must_use)]` on by default
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/main.rs:136:17
[INFO] [stdout]     |
[INFO] [stdout] 136 |                 socket.send_to(&data, addr).await;
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:392:9
[INFO] [stdout]     |
[INFO] [stdout] 392 |     let mut socket = crate::generate_socket(any_addr, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:398:9
[INFO] [stdout]     |
[INFO] [stdout] 398 |     let mut data = &mut arr[..];
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:47:16
[INFO] [stdout]    |
[INFO] [stdout] 47 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:66:16
[INFO] [stdout]    |
[INFO] [stdout] 66 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:69:17
[INFO] [stdout]    |
[INFO] [stdout] 69 |             Err(e) => {}
[INFO] [stdout]    |                 ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:82:16
[INFO] [stdout]    |
[INFO] [stdout] 82 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:85:17
[INFO] [stdout]    |
[INFO] [stdout] 85 |             Err(e) => {}
[INFO] [stdout]    |                 ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `send_bits_count_last`
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:103:13
[INFO] [stdout]     |
[INFO] [stdout] 103 |     let mut send_bits_count_last = 0usize;
[INFO] [stdout]     |             ^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_send_bits_count_last`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `pkg_num`
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:165:5
[INFO] [stdout]     |
[INFO] [stdout] 165 |     pkg_num: u32,
[INFO] [stdout]     |     ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_pkg_num`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `send_bits_count_last`
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:176:13
[INFO] [stdout]     |
[INFO] [stdout] 176 |     let mut send_bits_count_last = 0usize;
[INFO] [stdout]     |             ^^^^^^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_send_bits_count_last`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:247:9
[INFO] [stdout]     |
[INFO] [stdout] 247 |     let mut socket = crate::generate_socket(distributor_ip, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `trace`
[INFO] [stdout]  --> src/lib.rs:3:11
[INFO] [stdout]   |
[INFO] [stdout] 3 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^        ^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Mutex`
[INFO] [stdout]  --> src/lib.rs:4:22
[INFO] [stdout]   |
[INFO] [stdout] 4 | use std::sync::{Arc, Mutex};
[INFO] [stdout]   |                      ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `super::*`
[INFO] [stdout]  --> src/lib.rs:8:9
[INFO] [stdout]   |
[INFO] [stdout] 8 |     use super::*;
[INFO] [stdout]   |         ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `info`, `trace`, `warn`
[INFO] [stdout]  --> src/logger.rs:1:11
[INFO] [stdout]   |
[INFO] [stdout] 1 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^  ^^^^  ^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `SetLoggerError`
[INFO] [stdout]   --> src/logger.rs:48:24
[INFO] [stdout]    |
[INFO] [stdout] 48 | use log::{LevelFilter, SetLoggerError};
[INFO] [stdout]    |                        ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `dashmap::mapref::one::Ref`
[INFO] [stdout]  --> src/server.rs:1:5
[INFO] [stdout]   |
[INFO] [stdout] 1 | use dashmap::mapref::one::Ref;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `debug`, `error`, `trace`, `warn`
[INFO] [stdout]  --> src/server.rs:3:11
[INFO] [stdout]   |
[INFO] [stdout] 3 | use log::{debug, error, info, trace, warn};
[INFO] [stdout]   |           ^^^^^  ^^^^^        ^^^^^  ^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `HashSet`
[INFO] [stdout]   --> src/lib.rs:78:33
[INFO] [stdout]    |
[INFO] [stdout] 78 | use std::collections::{HashMap, HashSet};
[INFO] [stdout]    |                                 ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:248:9
[INFO] [stdout]     |
[INFO] [stdout] 248 |     let mut socket_parameter = crate::generate_socket(direct_ip, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:259:9
[INFO] [stdout]     |
[INFO] [stdout] 259 |     let mut buffer = vec![0u8; buffer_length];
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `recv_tcp_f64`
[INFO] [stdout]   --> src/bin/test_utils/sender.rs:76:10
[INFO] [stdout]    |
[INFO] [stdout] 76 | async fn recv_tcp_f64(stream: &TcpStream, buffer_length: usize) -> Result<f64, Box<dyn Error>> {
[INFO] [stdout]    |          ^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused implementer of `Future` that must be used
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:368:5
[INFO] [stdout]     |
[INFO] [stdout] 368 |     send_tcp(&stream_stop_2nd, data);
[INFO] [stdout]     |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_must_use)]` on by default
[INFO] [stdout]     = note: futures do nothing unless you `.await` or poll them
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused implementer of `Future` that must be used
[INFO] [stdout]    --> src/bin/test_utils/sender.rs:458:5
[INFO] [stdout]     |
[INFO] [stdout] 458 |     send_tcp(&stream_stop_2nd, data);
[INFO] [stdout]     |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: futures do nothing unless you `.await` or poll them
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:344:9
[INFO] [stdout]     |
[INFO] [stdout] 344 |     let mut socket = crate::generate_socket(distributor_ip, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:345:9
[INFO] [stdout]     |
[INFO] [stdout] 345 |     let mut socket_parameter = crate::generate_socket(direct_ip, recv_buffer, send_buffer).unwrap();
[INFO] [stdout]     |         ----^^^^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:356:9
[INFO] [stdout]     |
[INFO] [stdout] 356 |     let mut buffer = vec![0u8; buffer_length];
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:41:16
[INFO] [stdout]    |
[INFO] [stdout] 41 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:60:16
[INFO] [stdout]    |
[INFO] [stdout] 60 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:63:17
[INFO] [stdout]    |
[INFO] [stdout] 63 |             Err(e) => {}
[INFO] [stdout]    |                 ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `n`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:76:16
[INFO] [stdout]    |
[INFO] [stdout] 76 |             Ok(n) => {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_n`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]   --> src/bin/test_utils/receiver.rs:79:17
[INFO] [stdout]    |
[INFO] [stdout] 79 |             Err(e) => {}
[INFO] [stdout]    |                 ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `duration_time` is never read
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:168:25
[INFO] [stdout]     |
[INFO] [stdout] 168 |                         duration_time=watch.elapsed().unwrap().as_secs_f64();
[INFO] [stdout]     |                         ^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_assignments)]` on by default
[INFO] [stdout]     = help: maybe it is overwritten before being read?
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `time_limit`
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:140:5
[INFO] [stdout]     |
[INFO] [stdout] 140 |     time_limit: f64,
[INFO] [stdout]     |     ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_time_limit`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `buffer`
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:259:13
[INFO] [stdout]     |
[INFO] [stdout] 259 |     let mut buffer = vec![0u8; buffer_length];
[INFO] [stdout]     |             ^^^^^^ help: if this is intentional, prefix it with an underscore: `_buffer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `buffer`
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:356:13
[INFO] [stdout]     |
[INFO] [stdout] 356 |     let mut buffer = vec![0u8; buffer_length];
[INFO] [stdout]     |             ^^^^^^ help: if this is intentional, prefix it with an underscore: `_buffer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:105:17
[INFO] [stdout]     |
[INFO] [stdout] 105 |                 socket.recv(&mut buffer).await;
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_must_use)]` on by default
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:127:16
[INFO] [stdout]     |
[INFO] [stdout] 127 |                recv_tcp_u32(&stream_stop,buffer_length).await;
[INFO] [stdout]     |                ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:158:17
[INFO] [stdout]     |
[INFO] [stdout] 158 |                 socket.recv(&mut buffer).await;
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` that must be used
[INFO] [stdout]    --> src/bin/test_utils/receiver.rs:180:16
[INFO] [stdout]     |
[INFO] [stdout] 180 |                recv_tcp_u32(&stream_stop,buffer_length).await;
[INFO] [stdout]     |                ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:141:9
[INFO] [stdout]     |
[INFO] [stdout] 141 |         mut self,
[INFO] [stdout]     |         ----^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable expression
[INFO] [stdout]    --> src/server.rs:107:17
[INFO] [stdout]     |
[INFO] [stdout] 103 |                     return Ok("stop success");
[INFO] [stdout]     |                     ------------------------- any code following this expression is unreachable
[INFO] [stdout] ...
[INFO] [stdout] 107 |                 Err(warp::reject::not_found())
[INFO] [stdout]     |                 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ unreachable expression
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unreachable_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 9 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 29 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 25 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]   --> src/params.rs:15:17
[INFO] [stdout]    |
[INFO] [stdout] 15 | /                 (
[INFO] [stdout] 16 | |                     "127.0.0.1:19208".parse().unwrap(),
[INFO] [stdout] 17 | |                     "no comment".to_string(),
[INFO] [stdout] 18 | |                     true,
[INFO] [stdout] 19 | |                 ),
[INFO] [stdout]    | |_________________^ expected struct `Remote`, found tuple
[INFO] [stdout]    |
[INFO] [stdout]    = note: expected struct `Remote`
[INFO] [stdout]                found tuple `(_, std::string::String, bool)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0063]: missing field `recv_buffer` in initializer of `params::Distributor`
[INFO] [stdout]  --> src/params.rs:9:21
[INFO] [stdout]   |
[INFO] [stdout] 9 |         let dis_0 = Distributor {
[INFO] [stdout]   |                     ^^^^^^^^^^^ missing `recv_buffer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]   --> src/params.rs:38:17
[INFO] [stdout]    |
[INFO] [stdout] 38 | /                 (
[INFO] [stdout] 39 | |                     "127.0.0.1:19211".parse().unwrap(),
[INFO] [stdout] 40 | |                     "no comment".to_string(),
[INFO] [stdout] 41 | |                     true,
[INFO] [stdout] 42 | |                 ),
[INFO] [stdout]    | |_________________^ expected struct `Remote`, found tuple
[INFO] [stdout]    |
[INFO] [stdout]    = note: expected struct `Remote`
[INFO] [stdout]                found tuple `(_, std::string::String, bool)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0063]: missing field `recv_buffer` in initializer of `params::Distributor`
[INFO] [stdout]   --> src/params.rs:32:21
[INFO] [stdout]    |
[INFO] [stdout] 32 |         let dis_1 = Distributor {
[INFO] [stdout]    |                     ^^^^^^^^^^^ missing `recv_buffer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]   --> src/params.rs:71:17
[INFO] [stdout]    |
[INFO] [stdout] 71 | /                 (
[INFO] [stdout] 72 | |                     "127.0.0.1:19214".parse().unwrap(),
[INFO] [stdout] 73 | |                     "no comment".to_string(),
[INFO] [stdout] 74 | |                     true,
[INFO] [stdout] 75 | |                 ),
[INFO] [stdout]    | |_________________^ expected struct `Remote`, found tuple
[INFO] [stdout]    |
[INFO] [stdout]    = note: expected struct `Remote`
[INFO] [stdout]                found tuple `(_, std::string::String, bool)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0063]: missing field `recv_buffer` in initializer of `params::Distributor`
[INFO] [stdout]   --> src/params.rs:65:21
[INFO] [stdout]    |
[INFO] [stdout] 65 |         let dis_2 = Distributor {
[INFO] [stdout]    |                     ^^^^^^^^^^^ missing `recv_buffer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]   --> src/params.rs:94:17
[INFO] [stdout]    |
[INFO] [stdout] 94 | /                 (
[INFO] [stdout] 95 | |                     "127.0.0.1:19217".parse().unwrap(),
[INFO] [stdout] 96 | |                     "no comment".to_string(),
[INFO] [stdout] 97 | |                     false,
[INFO] [stdout] 98 | |                 ),
[INFO] [stdout]    | |_________________^ expected struct `Remote`, found tuple
[INFO] [stdout]    |
[INFO] [stdout]    = note: expected struct `Remote`
[INFO] [stdout]                found tuple `(_, std::string::String, bool)`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0063]: missing field `recv_buffer` in initializer of `params::Distributor`
[INFO] [stdout]   --> src/params.rs:88:21
[INFO] [stdout]    |
[INFO] [stdout] 88 |         let dis_3 = Distributor {
[INFO] [stdout]    |                     ^^^^^^^^^^^ missing `recv_buffer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0063]: missing field `send_buffer` in initializer of `params::Group`
[INFO] [stdout]    --> src/params.rs:121:27
[INFO] [stdout]     |
[INFO] [stdout] 121 |         let mut group_0 = Group { vec: vec![] };
[INFO] [stdout]     |                           ^^^^^ missing `send_buffer`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `get_plain_enable` found for struct `params::Group` in the current scope
[INFO] [stdout]    --> src/params.rs:126:34
[INFO] [stdout]     |
[INFO] [stdout] 126 |         println!("{:?}", group_0.get_plain_enable());
[INFO] [stdout]     |                                  ^^^^^^^^^^^^^^^^ help: there is an associated function with a similar name: `get_flat_enable`
[INFO] [stdout] ...
[INFO] [stdout] 217 | pub struct Group {
[INFO] [stdout]     | ---------------- method `get_plain_enable` not found for this
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0061]: this function takes 2 arguments but 1 argument was supplied
[INFO] [stdout]    --> src/params.rs:158:19
[INFO] [stdout]     |
[INFO] [stdout] 158 |         let res = Group::from_flat_enable(&flat);
[INFO] [stdout]     |                   ^^^^^^^^^^^^^^^^^^^^^^^ ----- supplied 1 argument
[INFO] [stdout]     |                   |
[INFO] [stdout]     |                   expected 2 arguments
[INFO] [stdout]     |
[INFO] [stdout] note: associated function defined here
[INFO] [stdout]    --> src/params.rs:249:12
[INFO] [stdout]     |
[INFO] [stdout] 249 |     pub fn from_flat_enable(
[INFO] [stdout]     |            ^^^^^^^^^^^^^^^^
[INFO] [stdout] 250 |         flat: &Vec<(usize, std::net::SocketAddr, Vec<std::net::SocketAddr>)>,
[INFO] [stdout]     |         --------------------------------------------------------------------
[INFO] [stdout] 251 |         send_buffer: usize,
[INFO] [stdout]     |         ------------------
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 11 previous errors; 10 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0061, E0063, E0308, E0599.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0061`.
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `data_distributor`
[INFO] [stderr] 
[INFO] [stderr] To learn more, run the command again with --verbose.
[INFO] running `Command { std: "docker" "inspect" "54173d058f502ccd288749721308b629969dffbadecdc37da85a6d7d9f7fe523", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "54173d058f502ccd288749721308b629969dffbadecdc37da85a6d7d9f7fe523", kill_on_drop: false }`
[INFO] [stdout] 54173d058f502ccd288749721308b629969dffbadecdc37da85a6d7d9f7fe523
